package com.bw.app.functions;

import org.apache.flink.streaming.connectors.kafka.partitioner.FlinkKafkaPartitioner;

public class MyPartitioner <T> extends FlinkKafkaPartitioner<T> {
    @Override
    public int partition(T t, byte[] bytes, byte[] bytes1, String s, int[] ints) {
        return 0;
    }



}
